package com.xavier.dong.netty.inboundhandlerandoutboundhandler;

import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelPipeline;
import io.netty.channel.socket.SocketChannel;

/**
 * @author XavierDong
 **/
public class MyClientInitializer extends ChannelInitializer<SocketChannel> {
    @Override
    protected void initChannel(SocketChannel ch) throws Exception {
        ChannelPipeline pipeline = ch.pipeline();

        // 加入 出站 的Handler 对 数据 进行一个编码
        pipeline.addLast(new MyLongToByteEncoder());

        // 这是 一个 入站的 解码器（Handler）
//        pipeline.addLast(new MyByteToLongDecoder());
        pipeline.addLast(new MyByteToLongDecoder2());

        // 加入 一个 自定义的 Handler 处理业务逻辑
        pipeline.addLast(new MyClientHandler());
    }
}
